package p270jp.pxv.android.notification.presentation.flux;

import androidx.lifecycle.AbstractC0720j0;
import p014ae.C0180w6;
import p189gn.AbstractC3446l;
import p216hn.Lambda;
import p290kk.NotificationsRepository;
import p318lk.NotificationSettingsService;
import p318lk.NotificationUrlParserService;
import p318lk.NotificationsService;
import p318lk.PixivNotificationsHasUnreadStateService;
import p325m0.MutabilityOwnership;
import p425pk.NotificationsAction;
import p436q6.C5768b;
import p467rd.subscribers;
import p493sf.AbstractC6043c;
import p603wm.Unit;
import p671zc.CompositeDisposable;
import p671zc.Disposable;

/* compiled from: NotificationsActionCreator.kt */
/* renamed from: jp.pxv.android.notification.presentation.flux.NotificationsActionCreator */
/* loaded from: classes2.dex */
public final class NotificationsActionCreator extends AbstractC0720j0 {

    /* renamed from: c */
    public final AbstractC6043c f19250c;

    /* renamed from: d */
    public final NotificationsService f19251d;

    /* renamed from: e */
    public final NotificationSettingsService f19252e;

    /* renamed from: f */
    public final NotificationUrlParserService f19253f;

    /* renamed from: g */
    public final PixivNotificationsHasUnreadStateService f19254g;

    /* renamed from: h */
    public final CompositeDisposable f19255h = new CompositeDisposable();

    /* compiled from: NotificationsActionCreator.kt */
    /* renamed from: jp.pxv.android.notification.presentation.flux.NotificationsActionCreator$a */
    /* loaded from: classes2.dex */
    public static final class C4303a extends Lambda implements AbstractC3446l<Throwable, Unit> {
        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C4303a() {
            super(1);
            NotificationsActionCreator.this = r1;
        }

        @Override // p189gn.AbstractC3446l
        public Unit invoke(Throwable th) {
            Throwable th2 = th;
            MutabilityOwnership.m3745m(th2, "it");
            NotificationsActionCreator.this.f19250c.mo2437b(new NotificationsAction.C5624a(th2));
            return Unit.f29503a;
        }
    }

    /* compiled from: NotificationsActionCreator.kt */
    /* renamed from: jp.pxv.android.notification.presentation.flux.NotificationsActionCreator$b */
    /* loaded from: classes2.dex */
    public static final class C4304b extends Lambda implements AbstractC3446l<NotificationsAction, Unit> {
        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C4304b() {
            super(1);
            NotificationsActionCreator.this = r1;
        }

        @Override // p189gn.AbstractC3446l
        public Unit invoke(NotificationsAction nVar) {
            NotificationsAction nVar2 = nVar;
            AbstractC6043c cVar = NotificationsActionCreator.this.f19250c;
            MutabilityOwnership.m3746l(nVar2, "action");
            cVar.mo2437b(nVar2);
            return Unit.f29503a;
        }
    }

    public NotificationsActionCreator(AbstractC6043c cVar, NotificationsService dVar, NotificationSettingsService bVar, NotificationUrlParserService cVar2, PixivNotificationsHasUnreadStateService eVar) {
        MutabilityOwnership.m3745m(cVar, "dispatcher");
        MutabilityOwnership.m3745m(eVar, "pixivNotificationsHasUnreadStateService");
        this.f19250c = cVar;
        this.f19251d = dVar;
        this.f19252e = bVar;
        this.f19253f = cVar2;
        this.f19254g = eVar;
    }

    @Override // androidx.lifecycle.AbstractC0720j0
    /* renamed from: b */
    public void mo315b() {
        this.f19255h.m80f();
    }

    /* renamed from: d */
    public final void m4564d() {
        this.f19250c.mo2437b(NotificationsAction.C5627d.f24812a);
        NotificationsRepository fVar = this.f19251d.f22594a;
        Disposable e = subscribers.m2591e(fVar.f20387a.mo1127a().m970f(new C5768b(fVar, 27)).m971e(new C0180w6(this, 9)).m970f(new C5768b(this, 28)), new C4303a(), new C4304b());
        CompositeDisposable aVar = this.f19255h;
        MutabilityOwnership.m3744n(aVar, "compositeDisposable");
        aVar.mo82c(e);
    }
}
